package o;

import androidx.annotation.NonNull;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

public class bpp {
    private static final bpp ˊ = new bpp();
    private final Queue<bpm> ॱ = new LinkedBlockingQueue();

    public static bpp ˏ() {
        return ˊ;
    }

    public void ˏ(@NonNull bpm o_bpm) {
        if (!this.ॱ.offer(o_bpm)) {
            boc.ˎ.ˊ("StartupListenerManager", "Unreachable, Fail to add the listener to the queue.");
        }
    }

    public void ˎ() {
        ˎ(true);
    }

    public void ˋ() {
        ˎ(false);
    }

    private void ˎ(boolean z) {
        bpm o_bpm = (bpm) this.ॱ.poll();
        while (o_bpm != null) {
            o_bpm.ˋ(z);
            o_bpm = (bpm) this.ॱ.poll();
        }
    }
}
